package org.zhadoop.stream.api.opereators;

import org.zhadoop.stream.cql.executor.operatorinfocreater.InputInfoCreator;
import org.zhadoop.stream.cql.executor.operatorinfocreater.OperatorInfoCreatorAnnotation;

/**
 * 基本的输入算子
 * @author zwd
 *
 */
@OperatorInfoCreatorAnnotation(InputInfoCreator.class)
public class InnerInputSourceOperator extends Operator{

	public InnerInputSourceOperator(String id, int parallelNumber) {
		super(id, parallelNumber);
	}
	
}
